package org.apache.flink.runtime.resourceprovider.slot;

import org.apache.flink.runtime.clusterframework.types.AllocationID;

/** Exception indicating that a {@link ConsumingTaskSlot} could not be found. */
public class SlotNotFoundException extends Exception {

    private static final long serialVersionUID = -883614807750137925L;

    public SlotNotFoundException(AllocationID allocationId) {
        this("Could not find slot for " + allocationId + '.');
    }

    public SlotNotFoundException(String message) {
        super(message);
    }
}
